﻿using RedisUtil;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace 消费者
{
    class Program
    {
        static void Main(string[] args)
        {

            ThreadPool.SetMaxThreads(100, 100);
            ThreadPool.SetMinThreads(10, 10);

            BaseRedis redis = new BaseRedis();

            var queueKey = "queue";

            while (true)
            {
                // 消费者：向Redis队列中获取数据（出队）。处理任务。
                var computerId = redis.DB.ListRightPop(queueKey);

                if (!string.IsNullOrEmpty(computerId))
                {
                    Console.WriteLine($"处理{computerId}的请求……");
                }

                Thread.Sleep(5);
            }
        }
    }
}
